package com.wk.springboot.parse.config;

import lombok.Data;

import java.util.HashMap;
import java.util.Map;

// Kafka终端配置
@Data
public class KafkaEndpointConfig {
    private String topic;
    private Integer partition;
    private String keySerializer = "org.apache.kafka.common.serialization.StringSerializer";
    private String valueSerializer = "org.apache.kafka.common.serialization.StringSerializer";
    private Map<String, String> properties = new HashMap<>();
}